package utils;

import com.hw.model.MetricDataBody;
import org.apache.flink.streaming.api.functions.ProcessFunction;
import org.apache.flink.util.Collector;

public class ModelMatchingFunction extends ProcessFunction<MetricDataBody, MetricDataBody> {
    @Override
    public void processElement(MetricDataBody metricDataBody, ProcessFunction<MetricDataBody, MetricDataBody>.Context context, Collector<MetricDataBody> collector) throws Exception {

    }
}
